//package org.mzy.basic.util;
//
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.core.RocketMQListener;
//import org.mzy.order.domain.MessageBody;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
//@RocketMQMessageListener(topic = "test-topic",nameServer = "${rocketmq.nameServer}",consumerGroup = "${rocketmq.consumer.group}", selectorExpression = "test-tag")
//@Component
//@Slf4j
//public class ComsumerListener implements RocketMQListener<MessageBody> {
//    @Autowired
////    private ItestService testService;
//    @Override
//    public void onMessage(MessageBody messageBody) {
//
//    System.out.println(messageBody);
//
//    }
//}
